package com.rocketmq.transaction.execult;

import com.rocketmq.MessageDto;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

/**
 * @author: hw
 * @date: 2021/3/8 17:19
 */
public interface RocketProducer {

    /**
     *  创建 DefaultMQProducer 实现
     * @param message  事务数据对象
     * @return
     */
    SendResult transactionExecute(Message message);
}
